package com.study.spmongodb.wwj.thread2.char15;

import java.util.stream.IntStream;

/**
 * @author MI
 * @version 1.0
 * @date 2020/12/8 22:54
 */
public class PerThreadClient {
    public static void main(String[] args) throws InterruptedException {
        final MessageHandler handler = new MessageHandler();

        IntStream.rangeClosed(1, 10).forEach(i -> {
            handler.requestNew(new Message(String.valueOf(i)));
        });
    }
}
